package topology;

import org.apache.storm.trident.operation.BaseFilter;
import org.apache.storm.trident.tuple.TridentTuple;

public class IpAreaFilter extends BaseFilter {
    @Override
    public boolean isKeep(TridentTuple tuple) {


        String guojia=tuple.getString(0);
        if (guojia.equals("中国"))
        return true;
        else
            return false;
    }
}
